package com.atguigu.gmall.realtime.app.func;

import com.alibaba.fastjson.JSONObject;

// 维度关联查询的接口

public interface DimJoinFunction<T> {
    //需要实现如何把结果装配给数据流对象
    //dimInfoJsonObj 异步查询结果
    //obj 数据流对象
    void join(JSONObject dimInfoJsonObj , T obj) throws Exception;

    //需要实现如何从流中对象获取主键
    //obj 数据流对象
    String getKey(T obj);
}
